bae1186b667836ab407e2c247e5b6a6cc1119f87,src/main/java/io/mycat/migrate/SwitchCommitListener.java,SwitchCommitListener,modifyZkRules,#CuratorTransactionFinal#String#List#,184

Before Change


                    if("count".equals(count.getString("name"))){
                        Integer xcount=Integer.parseInt( count.getString("value")) ;
                        count.put("value",String.valueOf(xcount+newDataNodes.size())) ;
                        transactionFinal.setData().forPath(rulePath,JSON.toJSONBytes(jsonArray)) ;
                    }
                }
            }

After Change


                        Integer xcount=Integer.parseInt( count.getString("value")) ;
                        count.put("value",String.valueOf(xcount+newDataNodes.size())) ;

                        if(transactionFinal==null){
                            transactionFinal=  ZKUtils.getConnection().inTransaction().setData().forPath(rulePath, JSON.toJSONBytes(jsonArray)).and();
                        }  else {
                            transactionFinal.setData().forPath(rulePath, JSON.toJSONBytes(jsonArray));
                        }
                    }
                }
            }

        }
        return transactionFinal;
    }

    private static CuratorTransactionFinal modifyTableConfigRules( CuratorTransactionFinal transactionFinal,String schemal,String table ,List<String> newDataNodes )